【SFA官方翻译】在Java中应用微服务开发RESTful APIs

原文链接：https://dzone.com/articles/developing-restful-apis-in-java-using-amazon-api-g

作者：Muhammad Ali

译者：Dom

本文旨在进一步学习如何利用Amazon API Gateway和AWS Lambda开发RESTful风格的Java API.

简介

AWS Lambda和Amazon API Gateway可用于实现基于Java语言的RESTful风格的web服务, 而且开发者不必考虑复杂的Java框架的配置, 或是搭建, 维护web服务器(如Tomcat, WebSphere, 等). 结合使用Lambda和API Gateway可使开发者非常轻松的开发API, 维护不同的开发环境, 比如开发(Dev), 测试(Test)和生产(Prod)环境等.

AWS Lambda是一种具备高扩展性, 高可用性的去服务器化的计算平台(serverless compute platform). 你可以在这种平台上运行你的Java代码来为你的服务提供主要功能. 请访问链接以了解更多关于Lambda的信息.

Amazon API Gateway是AWS众多网络服务中的一员. 它允许开发者轻松构建和部署API终端(endpoint). 它使开发者可以异常轻松得创建HTTPS终端并且集成Lambda函数(function). 数据交由API Gateway处理, 从API终端传输到Lambda函数. 请访问链接以了解更多关于API Gateway的信息.

本文将分步骤指导开发者如何使用Lambda和API Gateway开发Java RESTful风格微服务.

准备工作

首先, 你需要有一个可用的, 装有Java 8, Eclipse IDE和Eclipse AWS 工具集(Toolkit)的开发环境.

步骤1: 创建Lambda函数

一旦你有了可用的Eclipse IDE, 一个AWS图标将出现在主工具栏(main toolbar). 点击该图标并选择"新的AWS Lambda项目..."

配置合适的项目名和其他Maven配置. 选择"流式请求处理器"(Stream Request Handler)作为输入类型(Input type).

点击"完成"(Finish)后, 样例代码会自动生成到你新建的项目中. 打开主处理函数(main handler function)并更新如下代码段.

1. package com.amazonaws.lambda.demo;

2. import java.io.IOException;

3. import java.io.InputStream;

4. import java.io.OutputStream;

5. import java.io.InputStreamReader;

6. import java.io.OutputStreamWriter;

7. import java.io.BufferedReader;

8. import java.io.Writer;

9. import java.text.ParseException;

10. import java.util.ArrayList;

11. import java.util.HashMap;

12. import java.util.Map;

13. import com.amazonaws.services.lambda.runtime.RequestStreamHandler;

14. import com.amazonaws.services.lambda.runtime.Context;

15. import com.amazonaws.services.lambda.runtime.LambdaLogger;

16. import org.json.simple.JSONArray;

17. import org.json.simple.JSONObject;

18. import org.json.simple.parser.JSONParser;

19. import java.io.IOException;

20. import java.io.InputStream;

21. import java.io.OutputStream;

22. import com.amazonaws.services.lambda.runtime.Context;

23. import com.amazonaws.services.lambda.runtime.RequestStreamHandler;

24. public class LambdaFunctionHandler implements RequestStreamHandler

25. {

26. JSONParser parser = new JSONParser();

27.   @Override

28.   public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) throws IOException

29.   {

30.    LambdaLogger logger = context.getLogger();

31.       logger.log("Loading Java Lambda handler of ProxyWithStream");

32.       String proxy = null;

33. String param1 = null;

34. String param2 = null;

35. BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

36.       JSONObject responseJson = new JSONObject();

37.       String responseCode = "200";

38.       JSONObject event = null;

39.       try {

40.           event = (JSONObject)parser.parse(reader);

41.           if (event.get("pathParameters") != null) {

42.               JSONObject pps = (JSONObject)event.get("pathParameters");

43.               if ( pps.get("proxy") != null) {

44.                   proxy = (String)pps.get("proxy");

45.               }

46.           }

47.           if (event.get("queryStringParameters") != null)

48.           {

49.               JSONObject qps = (JSONObject)event.get("queryStringParameters");

50.               if ( qps.get("param1") != null)

51.               {

52.                   param1 = (String)qps.get("param1");

53.               }

54.           }

55.           if (event.get("queryStringParameters") != null)

56.           {

57.               JSONObject qps = (JSONObject)event.get("queryStringParameters");

58.               if ( qps.get("param2") != null)

59.               {

60.                   param2 = (String)qps.get("param2");

61.               }

62.           }

63.       }

64.       catch(Exception pex)

65.       {

66.        responseJson.put("statusCode", "400");

67.        responseJson.put("exception", pex);

68.       }

69.         // Implement your logic here

70.       int output = 0;

71.       if (proxy.equals("sum"))

72.       {

73.        output = sum(Integer.parseInt(param1), Integer.parseInt(param2));

74.       }

75.       else if (proxy.equals("subtract"))

76.       {

77.        output = subtract(Integer.parseInt(param1), Integer.parseInt(param2));

78.       }

79.        JSONObject responseBody = new JSONObject();

80.           responseBody.put("input", event.toJSONString());

81.           responseBody.put("message", "Output is" + output);

82.           JSONObject headerJson = new JSONObject();

83.           headerJson.put("x-custom-header", "my custom header value");

84.           headerJson.put("Access-Control-Allow-Origin", "*");

85.           responseJson.put("isBase64Encoded", false);

86.           responseJson.put("statusCode", responseCode);

87.           responseJson.put("headers", headerJson);

88.           responseJson.put("body", responseBody.toString());  

89.           OutputStreamWriter writer = new OutputStreamWriter(outputStream, "UTF-8");

90.           writer.write(responseJson.toJSONString());  

91.           writer.close();

92.   }

93.   public int sum(int a, int b)

94.   {

95.    return a+b;

96.   }

97.   public int subtract(int a, int b)

98.   {

99.    return a-b;

100.   }

101. }

构建并部署该Lambda函数. 完整的部署信息可以参考链接.

本例中我们以"RESTAPIHelloWorld"命名, 在AWS 控制台(console)中成功创建了Lambda函数.

步骤2: 创建API Gateway终端

到AWS 控制台中启动API Gateway服务. 点击"创建API"(Create API). 选择"新API"(New API)并命名之. 在创建了新的API后, 添加新的资源(Resource), 如下图:

请确保你选择了"配置为代理资源"(Configure as proxy resource)选项.

如下图中显示的 - "任意"(ANY)方法的设置, 选择"Lambda函数"作为集成类型(integration type). 同样的, 确保你选择了"使用Lambda代理集成"(Use Lambda Proxy integration)选项. 选择你想要部署Lambda函数的地理区域, 输入Lambda函数的名称.

现在我们将部署该API到特定环境中. 点击"操作"(Actions)下拉菜单并选择"部署API"(Deploy API).

选择"新环境"(New Stage)并输入环境名和简介. 在该教程中, 我们使用"开发"(Dev)作为环境名. 一旦部署完成, AWS 控制台将自动跳转到环境页面.

拷贝"调用URL"(Invoke URL)并将代理资源名和你想要传给你的Lambda函数的参数附在后面. 对于该教程, 可参考如下例子:

• 格式: https://5yv20hbz44.execute-api.eu-west-1.amazonaws.com/Dev/{proxy}?{setofparamsseparatedby_&}

• 例如: https://5yv20hbz44.execute-api.eu-west-1.amazonaws.com/Dev/sum?param1=100¶m2=100

输出如下:

小结

像AWS Lambda这样的去服务器化计算平台现今已非常流行. 许多组织都要求他们的自动化开发运维工程师(DevOps)具备开发去服务器化应用的能力. 如此即可降低安装硬件/软件设施的耗时, 也便缩减了项目交付的周期. 跟随本简单教程, 你应该可以使用Java上手开发去服务器化的AWS微服务了.

招人：数心，造化心数奇；用心等你...

上一篇：【SFA官方翻译】使用 Kubernetes、Spring Boot 2.0 和 Docker 的微服务快速指南

点击阅读原文查看更多

关注公众号